package com.asap.demo.sink;

import com.asap.rule.StandardEvent;
import org.apache.flink.configuration.Configuration;
import org.apache.flink.streaming.api.functions.sink.RichSinkFunction;

import java.util.List;

/**
 * @author wangbh
 * @Description: mysqlsink
 * @date 2021/12/7 9:56
 */
public class MysqlSink extends RichSinkFunction<List<StandardEvent>> {
    @Override
    public void open(Configuration parameters) throws Exception {
        super.open(parameters);
    }

    @Override
    public void invoke(List<StandardEvent> value, Context context) throws Exception {

    }

    @Override
    public void close() throws Exception {
        super.close();
    }
}
